package com.qingyan.flink.core.properties;

import com.qingyan.flink.core.model.SchemaMapping;
import lombok.Getter;
import lombok.Setter;

import java.util.List;
import java.util.Map;

/**
 * 同步规则
 *
 * @author csp 2023-12-23
 */
@Setter
@Getter
public class FlinkTransProperties {

    private String name;

    private String sources;

    private String sinks;

    private String

    private Map<String, String> sourceConfig;

    private Map<String, String> sinkConfig;

    private SchemaMapping schemaMapping;

    private String strategy;
}
